package com.qf.config;



import com.qianfeng.smsplatform.common.constants.RabbitMqConsants;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/*
 * @Data: 2021/7/14 19:57
 * */
@Configuration
public class RabbitConfig {

//          声明一个队列  主要目的是将通过初步审核的手机号和短信 内容封装后发送到 该队列 交给策略模块处理、、

    @Bean
    public Queue preSendQueue(){
        return new Queue(RabbitMqConsants.TOPIC_PRE_SEND,true) ;
    }
//    接受策略模块发送的 队列消息

    /**
     * 接收策略模块发送的状态报告的消息
     * @return
     */
    @Bean
    public Queue report(){
        return new Queue(RabbitMqConsants.TOPIC_PUSH_SMS_REPORT, true);
    }
}
